篇首语：本文由编程笔记#小编为大家整理，主要介绍了玩转Rabbitmq系列01:一文带你敲响Rabbitmq的大门相关的知识，希望对你有一定的参考价值。

&＃x1f3e0;个人主页&＃xff1a;啊陈晓

&＃x1f389;学习方向&＃xff1a;java后端开发

&＃x1f381;我的上一篇文章&＃xff1a;手把手带你搭建第一个SpringCloud项目&＃xff08;二&＃xff09;

&＃x1f495;如果我的文章对你有帮助&＃xff0c;点赞、收藏、留言都是对我最大的动力

【玩转Rabbitmq系列】文章直通车~

【玩转Rabbitmq系列】01:一文带你敲响Rabbitmq的大门

【玩转Rabbitmq系列】02:Rabbitmq保姆级安装教程与基本消息模型实战

  未完待续.........

现在让我们正式开启进入今天的正文

文章目录

• 前言

• 一、什么是Rabbitmq

• 二、为什么我们要使用消息中间件

• 三、选择Rabbitmq的原因

• 四、Rabbitmq的四大核心概念

• 五、Rabbitmq的六大消息模型

• 总结

前言

  在学习任何技术之前&＃xff0c;我们都必须要先了解这门技术的用处、选择这门技术的原因、能给自己带来什么样的帮助&＃xff0c;这样学习起来才会更有动力。而今天&＃xff0c;在我们正式开始学习Rabbitmq这门技术之前&＃xff0c;我们不妨先来了解一下什么是Rabbitmq,我们又为什么选择它。

---

一、什么是Rabbitmq

Rabbitmq是一个在AMQP(高级消息队列协议)基础上完成的&＃xff0c;可复用的企业消息系统&＃xff0c;用于软件之间的通信&＃xff0c;是当前最主流的消息中间件之一。

说到这里&＃xff0c;大家可能又会问了&＃xff0c;Rabbitmq的本质是一个消息中间件&＃xff0c;那什么又是消息中间件呢&＃xff1f; 

消息中间件就是利用高效可靠的消息传递机制进行异步的数据传输&＃xff0c;并基于数据通信进行分布式系统的集成。通过提供消息队列模型和消息传递机制&＃xff0c;可以在分布式环境下扩展进程间的通信。

人话&＃xff1a;应用之间的一个组件&＃xff0c;应用双方通过这个消息组件进行通信。

就如下图所示&＃xff0c;P、C之间中间是使用Rabbitmq来实现消息的传递、实现通信。

二、为什么我们要使用消息中间件

在现实的场景和应用中&＃xff0c;我们使用消息中间件&＃xff0c;主要是为了解决下面的这三个问题&＃xff1a;

1.应用解耦 

当今微服务架构盛行&＃xff0c;一个应用从传统的应用巨石被拆分成多个微服务&＃xff0c;在这个由众多系统构成的应用中&＃xff0c;如果采用传统的消息传递方式&＃xff0c;则会导致系统之间高度耦合&＃xff0c;严重影响系统的开发和维护效率。

举个例子:假设A有一份应用的核心数据&＃xff0c;B、C、D、E在需要数据时都必须对A发起请求&＃xff0c;如果系统的数量不多&＃xff0c;那A可以通过接口直接将数据传递给各个系统。但是如果系统的数量进一步增加&＃xff0c;A还要一个个将系统传递给几十甚至成百上千个系统吗&＃xff1f;如果其中系统中有一个瘫痪、抛出异常&＃xff0c;因为高度耦合的关系我们是不是也要去检查A中的业务逻辑&＃xff1f;这在实际开发中将严重影响到我们的开发效率和系统性能。

为了解决这个问题&＃xff0c;我们便引入消息中间件MQ

 如下图所示&＃xff0c;我们在A和其他系统中引入消息中间件MQ&＃xff0c;A将最核心的数据发送给消息中间件。其他系统通过MQ来实现对核心数据的访问&＃xff0c;即使系统数量发生变动也不会影响到A的业务逻辑&＃xff0c;实现了系统的解耦。

2.流量消峰 

还是举个例子:如果一个订单系统在一段时间内最高只能处理一万笔订单&＃xff0c;在正常时间段处理各种下单业务绰绰有余。但是在高峰期的时候&＃xff0c;订单的数量来到了两万笔&＃xff0c;此时系统便处理不了&＃xff0c;只能去限制超过一万订单的数量不能下单。这会严重影响到系统的可用性&＃xff0c;降低用户体验。

我们也可以通过引入MQ的方式解决上述问题

 如下图所示&＃xff0c;我们加入消息中间件对20000个请求进行缓冲&＃xff0c;把订单分散成一段时间进行处理。这样有一些用户可能会等待一小段时间&＃xff0c;但是这远比系统不可用的体验感要好得多。

3.异步处理

在传统的业务逻辑中&＃xff0c;业务之间的调用通常是顺序性&＃xff0c;在这种情况下&＃xff0c;即使业务之间的调用所消耗的时间很短&＃xff0c;但是因为业务太多也会导致整个业务逻辑时间执行下来花费太多的时间。

举个例子:我们在系统中发起一个请求时时&＃xff0c;需要经历如下图所示的业务链&＃xff1a;

因为业务链是顺序执行的&＃xff0c;所以执行完成共花费20ms.但是在一些复杂的业务系统中&＃xff0c;所需要付出的代价就远远不止20ms了&＃xff0c;因此我们必须找出更好的方案来减少整个业务完成的时间。

对于上述的问题&＃xff0c;我们还是可以通过引入消息中间件来解决。

 如下图所示&＃xff0c;我们以业务2、业务3为例&＃xff0c;让他们先将消息发送到消息中间件中&＃xff0c;后业务2、业务3下的其他业务再通过消息中间件来获取对应的消息&＃xff0c;让业务3不必等到业务2完全执行完再执行&＃xff0c;通过消息中间件实现了业务之间的异步处理。这便极大程度上缩短了业务的执行时间&＃xff0c;提高了系统的可用性。

三、选择Rabbitmq的原因

在现在的市场上&＃xff0c;有很多消息中间件的技术&＃xff0c;为什么我们选择了Rabbitmq&＃xff1f;

常见的消息中间件 

那是因为Rabbitmq具有下面的特性&＃xff1a;

• 遵循AMQP协议
• 可靠性高&＃xff0c;消息持久化能够能保证消息的稳定性
• 集群部署简单&＃xff0c;应用Erlang使得RabbitMQ集群部署变的超级简单
• WEB管理和监控&＃xff0c;为后期运维提供很大的便利
• 功能丰富&＃xff0c;支持消息持久化、支持消息确认机制、灵活的任务分发机
• 大量成功的应用案例&＃xff0c;例如阿里、网易等互联网巨头都有使用。

基于以上的特性&＃xff0c;对于市面上绝大多数中小型公司中数据量没有很大的项目来说。功能完备的Rabbitmq是一个非常好的选择。

四、Rabbitmq的四大核心概念

简单点来说&＃xff0c;Rabbitmq其实就像一个快递站点&＃xff0c;不过他所传递的是消息而并非快递&＃xff0c;接下来我们就以快递站点为例子引出Rabbitmq的四大核心概念。

在Rabbitmq中&＃xff0c;有着以下四大核心概念&＃xff1a;

•  生产者&＃xff08;producer&＃xff09;

生产者是产生数据发送消息的程序

• 交换机(exchange)

交换机是 RabbitMQ 非常重要的一个部件&＃xff0c;一方面它接收来自生产者的消息&＃xff0c;另一方面它将消息推送到队列中。交换机必须确切知道如何处理它接收到的消息&＃xff0c;是将这些消息推送到特定队列还是推送到多个队列&＃xff0c;亦或者是把消息丢弃&＃xff0c;这个得有交换机类型决定

• 队列(queue)

队列是 RabbitMQ 内部使用的一种数据结构&＃xff0c;尽管消息流经 RabbitMQ 和应用程序&＃xff0c;但它们只能存储在队列中。队列仅受主机的内存和磁盘限制的约束&＃xff0c;本质上是一个大的消息缓冲区。许多生产者可以将消息发送到一个队列&＃xff0c;许多消费者可以尝试从一个队列接收数据。这就是我们使用队列的方式

• 消费者(consumer)

消费与接收具有相似的含义。消费者大多时候是一个等待接收消息的程序。请注意生产者&＃xff0c;消费 者和消息中间件很多时候并不在同一机器上。同一个应用程序既可以是生产者又是可以是消费者。

简单来说&＃xff0c;拿快递站点来比喻&＃xff0c;生产者即是商家&＃xff0c;由商家&＃xff08;生产者&＃xff09;发出快递&＃xff08;信息&＃xff09;&＃xff0c;然后由快递站&＃xff08;交换机&＃xff09;接收&＃xff0c;快递站&＃xff08;交换机&＃xff09;必须知道快递&＃xff08;信息&＃xff09;是发往那条运行通道&＃xff08;队列&＃xff09;&＃xff0c;最终快递&＃xff08;消息&＃xff09;通过运行通道&＃xff08;队列&＃xff09;到达用户&＃xff08;消费者&＃xff09;手中。

五、Rabbitmq的六大消息模型

1、基本消息模型

即一个消费端&＃xff08;C&＃xff09;接收一个生产端&＃xff08;P&＃xff09;发送在消息队列&＃xff08;图中红色部分&＃xff09;中的信息。

2 、work消息模型

即两个消费端&＃xff08;C1&＃xff09;、&＃xff08;C2&＃xff09;共同消费一个生产端&＃xff08;P&＃xff09;发送在同一个消息队列&＃xff08;图中红色部分&＃xff09;中的信息&＃xff0c;但是一个消息只能被一个消费者获取&＃xff0c;C1、C2之间是竞争关系。

  3、Publish/subscribe模式

即生产者&＃xff08;P&＃xff09;将消息发送到交换机&＃xff08;X&＃xff09;中&＃xff0c;此处的交换机是Fanout(广播类型)&＃xff0c;交换机将消息广播发送给两个消息队列&＃xff08;图中两个红色部分&＃xff09;&＃xff0c;然后消费者C1、C2再分别从对应的队列中获取消息。

  4、Routing 路由模型

即生产者&＃xff08;P&＃xff09;将带着routing-key的消息发送到交换机&＃xff08;X&＃xff09;中&＃xff0c;此处的交换机是direct(直接类型)&＃xff0c;交换机将消息中routing-key与队列中所带的routing-key进行匹配,即图中的error、info、warning&＃xff0c;匹配成功则将消息发送给对应的消息队列&＃xff08;图中两个红色部分&＃xff09;&＃xff0c;然后消费者C1、C2再分别从对应的队列中获取消息。

  5、Topics 通配符模式

即生产者&＃xff08;P&＃xff09;将带着routing-key的消息发送到交换机&＃xff08;X&＃xff09;中&＃xff0c;此处的交换机是topic(主题模式)&＃xff0c;交换机将消息中routing-key与队列中所带的通配符进行匹配&＃xff0c;即图中的*.orange.*、*.*.rabbit、lazy.#&＃xff0c;匹配成功则将消息发送给对应的消息队列&＃xff08;图中两个红色部分&＃xff09;&＃xff0c;然后消费者C1、C2再分别从对应的队列中获取消息。

通配符规则&＃xff1a; 

#&＃xff1a;匹配0个或多个词

*&＃xff1a;匹配1个词

例子&＃xff1a;

*.orange.*&＃xff1a;成功&＃xff1a;a.orange.b、ok.orange.ok1      失败&＃xff1a;a.orange.b.c 、orange.b

 azy.#&＃xff1a;成功&＃xff1a;azy、azy.a、azy.b.c  失败&＃xff1a;a.azy

  6、RPC

1. 即客户端&＃xff08;P&＃xff09;启动时&＃xff0c;会创建一个匿名独享的回调队列(amqp.gen-Xa2)
2. 客户端&＃xff08;P&＃xff09;为RPC请求设置2个属性:replyTo&＃xff08;用于设置回调队列名字&＃xff09;&＃xff1b;correlationId&＃xff08;用于标记request&＃xff09;
3. 请求被发送到rpc_queue队列中
4. RPC服务器端&＃xff08;S&＃xff09;监听rpc_queue队列中的请求&＃xff0c;当请求到来时&＃xff0c;RPC服务器端&＃xff08;S&＃xff09;会处理并且把带有结果的消息发送给客户端&＃xff08;P&＃xff09;。接收的队列就是replyTo设定的回调队列。
5. 客户端&＃xff08;P&＃xff09;监听回调队列(amqp.gen-Xa2)&＃xff0c;当有消息时&＃xff0c;检查correlationId属性&＃xff0c;如果与request中匹配&＃xff0c;即取出结果

总结

  看到这里&＃xff0c;相信你已经对Rabbitmq有了一个初步的了解&＃xff0c;也许你还存在一些没有特别理解的地方&＃xff0c;没关系&＃xff0c;在接下的系列文章里&＃xff0c;我将从简单到复杂&＃xff0c;从配置到实现一步步带你深入Rabiitmq的世界&＃xff01;&＃xff01;

至此&＃xff0c;我们今天的教程就到此结束啦~

感谢您的阅读,希望我的文章能给你带来帮助&＃xff01;&＃xff01;&＃xff01;